
-- 初始化消息队列和消费者组

local queue_key = ARGV[1];
local group_name = ARGV[2];
-- 判断是否存在
if(redis.call('EXISTS',queue_key)==0) then
--    不存在
    redis.call('xgroup','create',queue_key,group_name,'0','MKSTREAM')
end
--存在
-- 在创建xgroup create stream.orders g1 0 mkstream
redis.call('xgroup','destroy',queue_key,group_name)
redis.call('xgroup','create',queue_key,group_name,'0','MKSTREAM')
